package RxJava;

public final class FlowableJust<T> extends Flowable<T> implements ScalarSupplier<T>{
    private final T value;
    public FlowableJust(final T value) {
        this.value = value;
    }

//    @Override
//    protected void subscribeActual(Subscriber<? super T> s) {
//        s.onSubscribe(new ScalarSubscription<>(s, value));
//    }

    @Override
    public T get() {
        return value;
    }
}
